package cn.getech.data.development.bean.jdbc

import cn.getech.data.development.enums.OutputFormat.OutputFormat
import cn.getech.data.development.enums.{FlinkStreamStartUpMode, OutputFormat}

case class KafkaResourceBean() {
  /* kafka */
  var typename: String = null
  /* topic name*/
  var topic: String = null
  /* 启动位置 */
  var startUp: String = null
  /* 参数设置 */
  var params: Array[JDBCFieldBean] = null
  /* format: json | csv */
  var format: String = null
  var formatType: OutputFormat = null
  /* format delimiter 分隔符 */
  var delimitFormat: Int = 5
  var delimitFormatType: String = null

  var startupMode = FlinkStreamStartUpMode.LATEST
}
